package cn.ecpark.service.kafka.spring.configuration;

import cn.ecpark.service.kafka.util.Topic;
import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

//   参考： 原文链接：https://blog.csdn.net/u010101193/article/details/117443638
@Configuration
public class KafkaConfiguration {

    // 创建一个名为testtopic的Topic并设置分区数为8，分区副本数为2
//    @Bean
//    public NewTopic creatTopic() {
//        return new NewTopic(Topic.NAME, 3 , (short) 2);
//    }

    // 如果要修改分区数，只需修改配置值重启项目即可
    // 修改分区数并不会导致数据的丢失，但是分区数只能增大不能减小
//    @Bean
//    public NewTopic updateTopic() {
//        return new NewTopic("mytopic",8, (short) 2 );
//    }
}
